home *** CD-ROM | disk | FTP | other *** search
/ SGI Freeware 2002 November / SGI Freeware 2002 November - Disc 1.iso / dist / fw_apache2.idb / usr / freeware / apache2 / include / fdqueue.h.z / fdqueue.h
C/C++ Source or Header  |  2002-07-08  |  4KB  |  107 lines
  1. /* ====================================================================
  2.  * The Apache Software License, Version 1.1
  3.  *
  4.  * Copyright (c) 2000-2002 The Apache Software Foundation.  All rights
  5.  * reserved.
  6.  *
  7.  * Redistribution and use in source and binary forms, with or without
  8.  * modification, are permitted provided that the following conditions
  9.  * are met:
  10.  *
  11.  * 1. Redistributions of source code must retain the above copyright
  12.  *    notice, this list of conditions and the following disclaimer.
  13.  *
  14.  * 2. Redistributions in binary form must reproduce the above copyright
  15.  *    notice, this list of conditions and the following disclaimer in
  16.  *    the documentation and/or other materials provided with the
  17.  *    distribution.
  18.  *
  19.  * 3. The end-user documentation included with the redistribution,
  20.  *    if any, must include the following acknowledgment:
  21.  *       "This product includes software developed by the
  22.  *        Apache Software Foundation (http://www.apache.org/)."
  23.  *    Alternately, this acknowledgment may appear in the software itself,
  24.  *    if and wherever such third-party acknowledgments normally appear.
  25.  *
  26.  * 4. The names "Apache" and "Apache Software Foundation" must
  27.  *    not be used to endorse or promote products derived from this
  28.  *    software without prior written permission. For written
  29.  *    permission, please contact apache@apache.org.
  30.  *
  31.  * 5. Products derived from this software may not be called "Apache",
  32.  *    nor may "Apache" appear in their name, without prior written
  33.  *    permission of the Apache Software Foundation.
  34.  *
  35.  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
  36.  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  37.  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  38.  * DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
  39.  * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  40.  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  41.  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
  42.  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  43.  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
  44.  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
  45.  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  46.  * SUCH DAMAGE.
  47.  * ====================================================================
  48.  *
  49.  * This software consists of voluntary contributions made by many
  50.  * individuals on behalf of the Apache Software Foundation.  For more
  51.  * information on the Apache Software Foundation, please see
  52.  * <http://www.apache.org/>.
  53.  *
  54.  * Portions of this software are based upon public domain software
  55.  * originally written at the National Center for Supercomputing Applications,
  56.  * University of Illinois, Urbana-Champaign.
  57.  */
  58.  
  59. #ifndef FDQUEUE_H
  60. #define FDQUEUE_H
  61. #include "httpd.h"
  62. #include <stdlib.h>
  63. #if APR_HAVE_UNISTD_H
  64. #include <unistd.h>
  65. #endif
  66. #include <apr_thread_mutex.h>
  67. #include <apr_thread_cond.h>
  68. #include <sys/types.h>
  69. #if APR_HAVE_SYS_SOCKET_H
  70. #include <sys/socket.h>
  71. #endif
  72. #include <apr_errno.h>
  73.  
  74. typedef struct fd_queue_info_t fd_queue_info_t;
  75.  
  76. apr_status_t ap_queue_info_create(fd_queue_info_t **queue_info,
  77.                                   apr_pool_t *pool, int max_idlers);
  78. apr_status_t ap_queue_info_set_idle(fd_queue_info_t *queue_info,
  79.                                     apr_pool_t *pool_to_recycle);
  80. apr_status_t ap_queue_info_wait_for_idler(fd_queue_info_t *queue_info,
  81.                                           apr_pool_t **recycled_pool);
  82. apr_status_t ap_queue_info_term(fd_queue_info_t *queue_info);
  83.  
  84. struct fd_queue_elem_t {
  85.     apr_socket_t      *sd;
  86.     apr_pool_t        *p;
  87. };
  88. typedef struct fd_queue_elem_t fd_queue_elem_t;
  89.  
  90. struct fd_queue_t {
  91.     fd_queue_elem_t    *data;
  92.     int                 nelts;
  93.     int                 bounds;
  94.     apr_thread_mutex_t *one_big_mutex;
  95.     apr_thread_cond_t  *not_empty;
  96.     int                 terminated;
  97. };
  98. typedef struct fd_queue_t fd_queue_t;
  99.  
  100. apr_status_t ap_queue_init(fd_queue_t *queue, int queue_capacity, apr_pool_t *a);
  101. apr_status_t ap_queue_push(fd_queue_t *queue, apr_socket_t *sd, apr_pool_t *p);
  102. apr_status_t ap_queue_pop(fd_queue_t *queue, apr_socket_t **sd, apr_pool_t **p);
  103. apr_status_t ap_queue_interrupt_all(fd_queue_t *queue);
  104. apr_status_t ap_queue_term(fd_queue_t *queue);
  105.  
  106. #endif /* FDQUEUE_H */
  107.